4a0f076d3605333a4d3030e6781b012bf7c4b68b,mule/src/test/java/org/mule/test/util/concurrent/WaitPolicyTestCase.java,WaitPolicyTestCase,testWaitPolicyWithTimeoutFailure,#,121

Before Change


			// expected
		}

		_executor.awaitTermination(3000, TimeUnit.MILLISECONDS);

		assertSame(s3, policy._lastRejected);
		assertEquals(0, _activeThreads);

After Change


        assertEquals(RejectedExecutionException.class, threadFailure.getValue().getClass());

        _executor.shutdown();
        boolean allFinished = _executor.awaitTermination(2500, TimeUnit.MILLISECONDS);
        assertTrue(allFinished);
        assertSame(s3, policy.lastRejectedRunnable());
        assertEquals(0, _activeTasks.get());